type golang.org/x/net/http2.stream
28 uses
golang.org/x/net/http2 (current package)
server.go#L413: streams: make(map[uint32]*stream),
server.go#L594: streams map[uint32]*stream
server.go#L645: type stream struct {
server.go#L678: func (sc *serverConn) state(streamID uint32) (streamState, *stream) {
server.go#L1152: func (sc *serverConn) writeDataFromHandler(stream *stream, data []byte, endStream bool) error {
server.go#L1698: func (sc *serverConn) closeStream(st *stream, err error) {
server.go#L1948: func (st *stream) isPushed() bool {
server.go#L1954: func (st *stream) endStream() {
server.go#L1970: func (st *stream) copyTrailersToHandlerRequest() {
server.go#L1981: func (st *stream) onReadTimeout() {
server.go#L1991: func (st *stream) onWriteTimeout() {
server.go#L2134: func (st *stream) processTrailerHeaders(f *MetaHeadersFrame) error {
server.go#L2183: func (sc *serverConn) newStream(id, pusherID uint32, state streamState) *stream {
server.go#L2190: st := &stream{
server.go#L2219: func (sc *serverConn) newWriterAndRequest(st *stream, f *MetaHeadersFrame) (*responseWriter, *http.Request, error) {
server.go#L2288: func (sc *serverConn) newWriterAndRequestNoBody(st *stream, rp httpcommon.ServerRequestParam) (*responseWriter, *http.Request, error) {
server.go#L2324: func (sc *serverConn) newResponseWriter(st *stream, req *http.Request) *responseWriter {
server.go#L2431: func (sc *serverConn) writeHeaders(st *stream, headerData *writeResHeaders) error {
server.go#L2463: func (sc *serverConn) write100ContinueHeaders(st *stream) {
server.go#L2473: st *stream
server.go#L2480: func (sc *serverConn) noteBodyReadFromHandler(st *stream, n int, err error) {
server.go#L2490: func (sc *serverConn) noteBodyRead(st *stream, n int) {
server.go#L2501: func (sc *serverConn) sendWindowUpdate32(st *stream, n int32) {
server.go#L2506: func (sc *serverConn) sendWindowUpdate(st *stream, n int) {
server.go#L2529: stream *stream
server.go#L2584: stream *stream
server.go#L3155: parent *stream
writesched.go#L57: stream *stream